package com.shujia.opt

import com.esotericsoftware.kryo.Kryo
import org.apache.spark.serializer.KryoRegistrator

/**
 * 自定义一个序列化类，指定kryo要序列化的东西
 */
class Demo8KryoRegistrator extends KryoRegistrator{

  override def registerClasses(kryo: Kryo): Unit = {

    /**
     * 在这个重写的方法中指定要序列化的东西
     *
     */
    kryo.register(classOf[Student])
    kryo.register(classOf[String])
    kryo.register(classOf[Int])


  }
}
